package day11.listdemo;

import redis.clients.jedis.Jedis;

import java.util.Random;
import java.util.UUID;

/**
 * 目标：模拟事务回滚？？？
 *      生产者，每隔2~3秒生成一个数据放到redis里；
 *      消费者，每隔2~3秒从redis消费一个数据 放到另一个缓存队列temp_redis里。如果放到缓存队列失败的话（自己定义的条件），
 *      就把该任务信息，从暂存队列中弹出来，再放到任务队列里等待继续消费。
 *
 */
public class TaskProducer {
    private static Jedis jedis = new Jedis("master", 6379);
    public static void main(String[] args) throws InterruptedException {
        Random r = new Random();

        while (true){
            int rint = r.nextInt(1000);
            Thread.sleep(2000+rint);
            String taskId = UUID.randomUUID().toString();

            jedis.lpush("task-queue1", taskId);
            System.out.println("生成一条任务信息：" + taskId);
        }
    }
}
